package com.example.basics.simpledelay;

import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RBlockingQueue;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;

@Slf4j
@Component
public class TakeTask {

    //由于项目启动只能一个跟着，因此注释掉该段代码

//    @Resource(name = "rBlockingQueue")
//    private RBlockingQueue<String> rBlockingQueue;
//
//
//    @PostConstruct
//    public void take() {
//        //由于此线程需要常驻，可以新建线程，不用交给线程池管理
//        new Thread(() -> {
//            while (true) {
//                try {
//                    String s = rBlockingQueue.take();
//                    log.info("取出消息：{}", s);
//                } catch (InterruptedException e) {
//                    e.printStackTrace();
//                }
//            }
//        }).start();
//        log.info("队列启动成功");
//    }

}
